//package org.cuit.seon.service;
//
//import java.util.concurrent.BlockingQueue;
//import java.util.concurrent.LinkedBlockingQueue;
//
///**
// * 队列认证规划器
// */
//public class QueueAuthPlaner {
//    public static final BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>();
//
//
//
//    public static String token() {
//        Thread producer = new Thread(new ProductDemo());
//        Thread consumer = new Thread(new ConsumerDemo());
//        producer.start();
//        consumer.start();
//        return null;
//    }
//
//    /**
//     * 生产者
//     */
//    private static class ProductDemo implements Runnable {
//        RequestExecutor executor = new RequestExecutor();
//
//        @Override
//        public void run() {
//            try {
//                workQueue.put(executor::refreshToken);
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//        }
//    }
//
//    /**
//     * 消费者
//     */
//    private static class ConsumerDemo implements Runnable {
//        //工作队列
//        @Override
//        public void run() {
//            try {
//                while (true) {
//                    Runnable task = workQueue.take();
//                    new Thread(task).start();
//                    // 完成了之后需要清空队列
//                    workQueue.clear();
//                }
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//        }
//    }
//}